Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / SessionManagerImplTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787app.cash.turbine.test

Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi

Tff7b72import T7ee787kotlinx.coroutines.flow.first

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787okio.ByteString

Tff7b72import T7ee787org.meshtastic.core.model.SessionStatus

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertIs

Tff7b72import T7ee787kotlin.test.assertSame

Tff7b72import T7ee787kotlin.time.Clock

Tff7b72import T7ee787kotlin.time.Duration.Companion.seconds

Tff7b72import T7ee787kotlin.time.Instant

Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)

Tff7b72class T56d364SessionManagerImplTest Tb4b4b4{

Tff7b72private Tff7b72class T56d364MutableClockTb4b4b4(Tff7b72var Te6edf3nowTb4b4b4: Te6edf3Instant Tff7b72= Te6edf3InstantTb4b4b4.Te6edf3fromEpochSecondsTb4b4b4(T79c0ff1Te6edf3_700_000_000Tb4b4b4)Tb4b4b4) Tb4b4b4: Te6edf3Clock Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffnowTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3Instant Tff7b72= Te6edf3now

Tb4b4b4}

Tff7b72private Tff7b72val Te6edf3nodeA Tff7b72= T79c0ff0Te6edf3xAAAA

Tff7b72private Tff7b72val Te6edf3nodeB Tff7b72= T79c0ff0Te6edf3xBBBB

Tff7b72private Tff7b72val Te6edf3keyA Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3ofTb4b4b4(T79c0ff1Tb4b4b4, T79c0ff2Tb4b4b4, T79c0ff3Tb4b4b4, T79c0ff4Tb4b4b4, T79c0ff5Tb4b4b4, T79c0ff6Tb4b4b4, T79c0ff7Tb4b4b4, T79c0ff8Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3keyB Tff7b72= Te6edf3ByteStringTb4b4b4.Te6edf3ofTb4b4b4(T79c0ff9Tb4b4b4, T79c0ff8Tb4b4b4, T79c0ff7Tb4b4b4, T79c0ff6Tb4b4b4, T79c0ff5Tb4b4b4, T79c0ff4Tb4b4b4, T79c0ff3Tb4b4b4, T79c0ff2Tb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8ff`recordSession stores per-node passkeys without overwriting siblings`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3MutableClockTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3keyATb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeBTb4b4b4, Te6edf3keyBTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3keyATb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3getPasskeyTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3keyBTb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3getPasskeyTb4b4b4(Te6edf3nodeBTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`recordSession with empty passkey is a no-op`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3MutableClockTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4)

Te6edf3assertSameTb4b4b4(Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3getPasskeyTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`clearAll wipes per-node entries`Tb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3MutableClockTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3keyATb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeBTb4b4b4, Te6edf3keyBTb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3clearAllTb4b4b4(Tb4b4b4)

Te6edf3assertSameTb4b4b4(Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3getPasskeyTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4)

Te6edf3assertSameTb4b4b4(Te6edf3ByteStringTb4b4b4.Te6edf3EMPTYTb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3getPasskeyTb4b4b4(Te6edf3nodeBTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`observeSessionStatus emits NoSession initially when no key recorded`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3MutableClockTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3SessionStatusTb4b4b4.Te6edf3NoSessionTb4b4b4, Te6edf3mgrTb4b4b4.Te6edf3observeSessionStatusTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`observeSessionStatus reports Active for a fresh recording`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3clock Tff7b72= Te6edf3MutableClockTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3clockTb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3keyATb4b4b4)

Tff7b72val Te6edf3status Tff7b72= Te6edf3mgrTb4b4b4.Te6edf3observeSessionStatusTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Te6edf3assertIsTff7b72<Te6edf3SessionStatusTb4b4b4.Te6edf3ActiveTff7b72>Tb4b4b4(Te6edf3statusTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3clockTb4b4b4.Te6edf3nowTb4b4b4, Te6edf3statusTb4b4b4.Te6edf3refreshedAtTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`observeSessionStatus reports Stale once age exceeds threshold`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3clock Tff7b72= Te6edf3MutableClockTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3clockTb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3keyATb4b4b4)

T8b949e// Age past the 240s active threshold; still under firmware TTL of 300s.

Te6edf3clockTb4b4b4.Te6edf3now Tff7b72= Te6edf3clockTb4b4b4.Te6edf3nowTb4b4b4.Te6edf3plusTb4b4b4(T79c0ff2T79c0ff5T79c0ff0.Te6edf3secondsTb4b4b4)

Tff7b72val Te6edf3status Tff7b72= Te6edf3mgrTb4b4b4.Te6edf3observeSessionStatusTb4b4b4(Te6edf3nodeATb4b4b4)Tb4b4b4.Te6edf3firstTb4b4b4(Tb4b4b4)

Te6edf3assertIsTff7b72<Te6edf3SessionStatusTb4b4b4.Te6edf3StaleTff7b72>Tb4b4b4(Te6edf3statusTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`sessionRefreshFlow emits srcNodeNum on each non-empty recording`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3mgr Tff7b72= Te6edf3SessionManagerImplTb4b4b4(Te6edf3MutableClockTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3sessionRefreshFlowTb4b4b4.Te6edf3test Tb4b4b4{

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3keyATb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3nodeATb4b4b4, Te6edf3awaitItemTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3mgrTb4b4b4.Te6edf3recordSessionTb4b4b4(Te6edf3nodeBTb4b4b4, Te6edf3keyBTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3nodeBTb4b4b4, Te6edf3awaitItemTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3cancelAndIgnoreRemainingEventsTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tb4b4b4}